package com.ot.flink.cdc.biz.service;

import com.ot.flink.cdc.biz.domain.CdcTask;

import java.util.List;

/**
 * @author: admin
 * @date: 2024/5/24
 * @since JDK1.8 version: 1.0.0
 */
public interface TaskService {
    void addTask(CdcTask taskInfo);

    void stopOrStartTask(CdcTask cdcTask);

    CdcTask getTask(String name);

    List<CdcTask> getAllTask();
}
